package com.steak.bootactivemq.test;

import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.jms.*;
import java.util.Queue;
import java.util.UUID;

@Component
public class Producer {
//    @Autowired
//    private JmsMessagingTemplate jmsMessagingTemplate;
//
//    @Autowired
//    private Queue queue;
//
//
//
//    public void produceMsg(){
//        jmsMessagingTemplate.convertAndSend(queue,"boot-test"+ UUID.randomUUID().toString().substring(0,17).replace("-",""));
//    }
//
//    //间隔定投
//    @Scheduled(fixedDelay = 3000) //三秒钟往队列里投递一次消息
//    public void produceMsgScheduled() throws JMSException {
//        jmsMessagingTemplate.convertAndSend(queue,"间隔定投  "+UUID.randomUUID().toString().substring(0,17).replace("-",""));
//        System.out.println("定时投递消息  ");
//    }
}
